6d94a8fe624160ee0dc0e42ed8be51c570347cc0,mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraUidProvider.java,CassandraUidProvider,tryUpdateUid,#CassandraId#com.google.common.base.Optional#,125
Before Change
update(CassandraMessageUidTable.TABLE_NAME)
.onlyIf(eq(NEXT_UID, null))
.with(set(NEXT_UID, MessageUid.MIN_VALUE.asLong()))
.where(eq(CassandraMessageUidTable.MAILBOX_ID, mailboxId.asUuid())));
}
}
After Change
if (uid.isPresent()) {
MessageUid nextUid = uid.get().next();
return executor.executeReturnApplied(
updateStatement.bind()
.setUUID(MAILBOX_ID, mailboxId.asUuid())
.setLong(CONDITION, uid.get().asLong())
.setLong(NEXT_UID, nextUid.asLong()))
.thenApply(success -> successToUid(nextUid, success));
} else {